<?php

ini_set('default_socket_timeout', -1);  // 方式一：php配置设置不超时
$redis = new \Redis();
$redis->connect("127.0.0.1", 6379);
//$redis->setOption(Redis::OPT_READ_TIMEOUT, -1); //方式二：redis方式设置不超时，推荐

// 此方法将会挂起程序
$redis->subscribe(['chan-1', 'chan-2'], 'task');  // 第一个参数为订阅哪个频道，第二个参数为响应回调函数名称

// 回调函数,这里写处理逻辑
function task($instance, $channelName, $message)
{
    $newredis = new Redis();
    $newredis->connect("127.0.0.1", 6379);
    echo $newredis->get('key_1') . PHP_EOL; // 也可操作操作redis
    $newredis->close();
    switch ($channelName) {
        case 'chan-1':
            var_dump('chan-1' . $message);
            break;
        case 'chan-2':
            var_dump('chan-2' . $message);
            break;
    }
}